package zhongbo.java.air.fightpath.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;

/**
 * 接收订阅频道log_chanel 发布的广播消息
 */
@Component
@Slf4j
public class RedisSubscribeLogChanelListener implements MessageListener {

    /**
     * 消息处理方法
     *
     * @param message 消息内容对象
     * @param chanel  字节数组方式的频道名称
     */
    @Override
    public void onMessage(Message message, byte[] chanel) {
        byte[] messageBody = message.getBody();
        String msgString = new String(messageBody);
        log.info("收到日志消息 {}", msgString);
    }
}
